b73a2229e5a4958edc5c4ff541ebf93bc7ba45c5,src/org/jgroups/stack/Retransmitter.java,Retransmitter,add,#number#number#,94
Before Change
synchronized(msgs) {
msgs.add(entry);
}
entry.doSchedule(timer); // Entry adds itself to the timer
}
/**
After Change
}
Task task;
for(long seqno=first_seqno; seqno <= last_seqno; seqno++) {
// each task needs its own retransmission interval, as they are stateful *and* mutable, so we *need* to copy !
task=new Task(seqno, RETRANSMIT_TIMEOUTS.copy(), cmd, sender);
msgs.putIfAbsent(seqno, task);
task.doSchedule(timer); // Entry adds itself to the timer
}
}